package com.aviator.detective.execute.listener;

import com.aviator.detective.execute.event.ProcessExecuteCompleteEvent;
import com.aviator.detective.execute.event.ProcessExecuteErrorEvent;
import com.aviator.detective.execute.event.ProcessExecuteStartEvent;
import com.aviator.detective.execute.eventbus.AllAllowConcurrentEvents;
import com.aviator.detective.execute.eventbus.AllSubscribe;

/**
 * 规则流执行结果上下文信息通过kafka消费后，经过flink实时处理
 */
@AllSubscribe
@AllAllowConcurrentEvents
public class KafkaSinkExecuteElementListener implements ProcessExecuteListener{

    @Override
    public void processStart(ProcessExecuteStartEvent event) {

    }

    @Override
    public void processComplete(ProcessExecuteCompleteEvent event) {

    }

    @Override
    public void processError(ProcessExecuteErrorEvent event) {

    }
}
